package com.dongline.te

import javafx.application.Application
import javafx.stage.Stage
import org.apache.spark.{SparkConf, SparkContext}

class WangZhanLiulanliang extends Application{

  var inputmin = 0

  override def start(primaryStage: Stage): Unit = {

    //每一个学科访问页面最多的前几名

    //1，创建spark设置对象
    val conf = new SparkConf().setAppName("Wangye").setMaster("local[2]")
    conf.set("spark.testing.memory", "471859200")
    //2，创建spark程序对象
    val  sc:SparkContext = new SparkContext(conf)
    val rdd1 =sc.textFile("D://itcast.log").map(x => x.split("\t"))
    
   print(rdd1.collect.toBuffer)


  }
}
